//package com.after.saas.user.rocketmq.consumer;//package com.after.saas.system.rocketmq.listener;
//
//import com.after.saas.user.service.UserService;
//import com.after.saas.common.model.bo.UserBO;
//import com.after.saas.common.model.vo.UserVO;
//import com.after.saas.mq.constants.Topics;
//import com.alibaba.fastjson.JSON;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//
//import java.util.List;
//
//@Slf4j
//@Service
//@RocketMQMessageListener(topic = Topics.TOPIC_USER, consumerGroup = "Group-" + Topics.TOPIC_USER)
//public class UserMessageConsumer implements RocketMQListener<List<UserBO>> {
//
//    @Autowired
//    private UserService userService;
//
//    @Override
//    public void onMessage(List<UserBO> message) {
//        try {
//            userService.batchSave(message);
//        } catch (Exception e) {
//            e.printStackTrace();
//            log.error("errorMsg {}", e.getMessage());
//        }
//    }
//}
